package org.example.configuration;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author Tang
 * @classname RabbitMqConfiguration
 * @description [  ]
 * @date 2023/4/10 21:07
 */
@Configuration
public class RabbitMqConfiguration {

    @Bean
    public Queue createTest01Queue() {
        return new Queue("ex.tang.test01",true,false,true);
    }

    @Bean
    public Queue createErrorQueue() {
        return new Queue("ex.tang.error",true,false,true);
    }

    @Bean
    public Queue createError01Queue() {
        return new Queue("ex.tang.error.1",true,false,true);
    }

//    @Bean
//    public TopicExchange errorExchange() {
//        return new TopicExchange("ex.tang.error-exchange",true,false);
//    }



}
